package com.lzy.gmall.realtime.app.ods;


import com.lzy.gmall.realtime.utils.MysqlUtil;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.TableResult;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class Ods_Raw_data {
    public static void main(String[] args) throws Exception {
//        TODO 1.设置流环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        TODO 2.设置并行度
        env.setParallelism(1);
//        TODO 3.设置表环境
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

        env.execute();
    }
}
